package com.example.demo;

import rx.Producer;
import rx.Subscriber;

public class BaseSubscriber<T> extends Subscriber<T> {

    @Override
    public void onStart() {
        super.onStart();
    }

    @Override
    public void setProducer(Producer p) {
        super.setProducer(p);
    }

    @Override
    public void onCompleted() {

    }

    @Override
    public void onError(Throwable throwable) {

    }

    @Override
    public void onNext(T t) {
        if (t != null){
            System.out.println(t);
        }else {
            System.out.println("error");
        }
    }
}
